7a757f461ac3132b81d96d92b7a033ca7c05bb45,src/main/java/com/spotify/hdfs2cass/cassandra/cql/CrunchCqlBulkRecordWriter.java,CrunchCqlBulkRecordWriter,close,#,146

Before Change


        Future<StreamState> future =
            loader.stream(Collections.<InetAddress>emptySet(), new ProgressIndicator());
        try {
          Uninterruptibles.getUninterruptibly(future);
        } catch (ExecutionException e) {
          throw new RuntimeException("Streaming to the following hosts failed: " +
              loader.getFailedHosts(), e);

After Change


        Future<StreamState> future =
            loader.stream(Collections.<InetAddress>emptySet(), new ProgressIndicator());
        try {
          StreamState streamState = Uninterruptibles.getUninterruptibly(future);
          if (streamState.hasFailedSession()) {
            LOG.warn("Some streaming sessions failed");
          } else {
            LOG.info("Streaming finished successfully");
          }